import java.util.concurrent.Future;

import org.apache.kafka.clients.producer.RecordMetadata;

import com.tsx.kafka.product.KafkaUtil;

public class kafkaProductDemo {

	
	public static void main(String[] args) throws Exception {
		  int partition=0;
		for (int i = 0; i < 30; i++) {
		   Future<RecordMetadata> fult = KafkaUtil.send("jiuzhi_word",partition,"carNowFlag", "org.apache.storm.LocalCluster$_submitTopology invoke LocalCluster "+i);
		    System.out.println(fult.get().offset()+"--------"+fult.get().partition());
		}
		
	}
}
